<%@ page language="java" contentType="text/html; charset=UTF-8"
	pageEncoding="UTF-8"%>
<!DOCTYPE HTML>
<html> 
	<head>
		<title>测试</title> 
		<%@ include  file="/WEB-INF/oss/base/common/variable.jsp"%>
    	<%@ include  file="/WEB-INF/oss/base/common/resource_lib.jsp"%>
    	<%@ include  file="/WEB-INF/oss/base/common/variable_js.jsp"%>
    	
    	<script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>
		
	</style>
	</head>
	<body>
		
		nihao hello 
		
	</body>
	
	<script type="text/javascript">
		
	
	// 连接选项
	const options = {
	      connectTimeout: 4000, // 超时时间
	      // 认证信息
	      clientId: '426aad8a150a4d85a8fa7221085edca3_21212',
	      username: 'iot2yun',
	      password: 'iot2yun',
	}

		var client = mqtt.connect('ws://47.107.108.69:8083/mqtt', options)
	
		client.on('reconnect', function(error)  {
		    console.log('正在重连:', error)
		})
	
		client.on('error', function(error) {
		    console.log('连接失败:', error)
		})
		
	
		client.on('connect', function() {

			client.subscribe('/alarm/iid');
			client.subscribe('/sensor/+');
		})

		client.on('message', function(topic, message) {
			// message is Buffer
			console.log(topic);
			console.log(message.toString())
// 			client.end()
		})
		
		setInterval( function()  {
			client.publish('/alarm/iid', 'Hello mqtt2 111') ;
		}, 1100);
		
		setTimeout(function() {
			client.publish('/sensor/aa', 'Hello sensor') ;
		}, 1000);
	</script>
	
</html>
